#include"Ringqueue.hpp"
#include<iostream>
#include<unistd.h>



void* get(void*argv)
{
    sleep(2);
    int data;
    while(1)
    {
        rq.Get(&data);
        sleep(1);
        cout<<"获得数据:"<<data<<endl;
    }
    return nullptr;
}

void* set(void*argv)
{
    cout<<"set"<<endl;
    int data=1;
    while (1)
    {
        cout<<"写入数据:"<<data;
        rq.Set(&data);
        data++;
        sleep(1);
    }
    
    return nullptr;
}


int main()
{

    pthread_t c1,p1;

    pthread_create(&c1,nullptr,get,nullptr);
    pthread_create(&p1,nullptr,set,nullptr);    
    cout<<"创建线程成功"<<endl;
    pthread_join(c1,nullptr);
    pthread_join(p1,nullptr);
    return 0;
}
